type google.golang.org/grpc/internal/transport.controlBuffer
13 uses
google.golang.org/grpc/internal/transport (current package)
controlbuf.go#L307: type controlBuffer struct {
controlbuf.go#L327: func newControlBuffer(done <-chan struct{}) *controlBuffer {
controlbuf.go#L328: return &controlBuffer{
controlbuf.go#L338: func (c *controlBuffer) throttle() {
controlbuf.go#L348: func (c *controlBuffer) put(it cbItem) error {
controlbuf.go#L360: func (c *controlBuffer) executeAndPut(f func() bool, it cbItem) (bool, error) {
controlbuf.go#L404: func (c *controlBuffer) get(block bool) (any, error) {
controlbuf.go#L431: func (c *controlBuffer) getOnceLocked() (any, error) {
controlbuf.go#L454: func (c *controlBuffer) finish() {
controlbuf.go#L515: cbuf *controlBuffer
controlbuf.go#L542: func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator, conn net.Conn, logger *grpclog.PrefixLogger, goAwayHandler func(*goAway) (bool, error), bufferPool mem.BufferPool) *loopyWriter {
http2_client.go#L98: controlBuf *controlBuffer
http2_server.go#L90: controlBuf *controlBuffer